package com.artlongs.webapp.service.reactor;


import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import reactor.core.Reactor;
import reactor.event.Event;
import reactor.spring.context.annotation.Consumer;
import reactor.spring.context.annotation.ReplyTo;
import reactor.spring.context.annotation.Selector;


@Consumer
public class HandlerBean {

    @Selector(value="test.topic", reactor="@reactor")
    public void handleTestTopic(Event<String> evt) {
        // handle the event
    }


}